package com.qupeng.demo.kafka.kafkaspringbootstreams.common.kafka.streams;

import org.apache.kafka.common.serialization.Serdes;
import org.springframework.kafka.support.serializer.JsonDeserializer;
import org.springframework.kafka.support.serializer.JsonSerializer;

public class JsonSerde<T> extends Serdes.WrapperSerde<T> {
    public JsonSerde(Class classType) {
        super(new JsonSerializer<T>(), new JsonDeserializer<T>(classType, false));
    }
}